package com.yc.jms.demo1;

import javax.jms.*;
import javax.naming.*;

public class C1 {
	
	public void m1() {
//		QueueConnectionFactory queueConnFactory = (QueueConnectionFactory) initialCtx.lookup ("primaryQCF");
//		Queue purchaseQueue = (Queue) initialCtx.lookup ("Purchase_Queue");
//		Queue returnQueue = (Queue) initialCtx.lookup ("Return_Queue");
	}

	public void producer() {
//		//创建文本消息
//		TextMessage textMessage = session.createTextMessage("消息内容" + (i + 1 ));
//		//消息发送的目的地
//		textMessage.setJMSDestination(new Queue(){
//		    @Override
//		    public String getQueueName() throws JMSException {
//		        return name;
//		    }
//		});
//		//消息的发送模式
//		textMessage.setJMSDeliveryMode(DeliveryMode.NON_PERSISTENT);
//		//消息ID
//		textMessage.setJMSMessageID("ID:JMSMessageID");
//		//消息发送时的时间
//		textMessage.setJMSTimestamp(1000);
//		//关联的消息ID
//		textMessage.setJMSCorrelationID("100:JMSCorrelationID");
//		//消息回复的目的地
//		textMessage.setJMSReplyTo(new Queue(){
//		    @Override
//		    public String getQueueName() throws JMSException {
//		        return name;
//		    }
//		});
//		//消息是否重复发送过
//		textMessage.setJMSRedelivered(true);
//		//消息类型，代表消息的结构
//		textMessage.setJMSType("type");
//		//消息的过期时间，以毫秒为单位
//		textMessage.setJMSExpiration(36000);
//		//消息的优先级,0-4为普通的优化级，而5-9为高优先级
//		textMessage.setJMSPriority(5);
	}
	
}
